#include "ThreadRecolectorDePeersNoActivos.h"

ThreadRecolectorDePeersNoActivos::ThreadRecolectorDePeersNoActivos(list<InterfazPeer*>* listaPeers, Condition* condListaPeers, unsigned int tiempoEspera) {

	this->listaPeers = listaPeers;
	this->condListaPeers = condListaPeers;
	this->tiempoEspera = tiempoEspera;
}

ThreadRecolectorDePeersNoActivos::~ThreadRecolectorDePeersNoActivos() {

}

void* ThreadRecolectorDePeersNoActivos::run() {

	while (!this->getStop()) {

		this->condListaPeers->mutexLock();
		list<InterfazPeer*>::iterator it = this->listaPeers->begin();

		for ( ; it != this->listaPeers->end(); it++){
			InterfazPeer* interfazActual = *it;

			if (!interfazActual->getActivo()){
				this->listaPeers->erase(it);
				//TODO ver de donde sacarlo al chabon, comprendes?
			}
		}

		this->condListaPeers->mutexUnlock();
	}

	return NULL;
}

void ThreadRecolectorDePeersNoActivos::stop() {

}
